package com.mriassl.rabbitmq.base;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

public abstract class AbstractProducer extends BaseConnection {

	protected abstract void doSometing(Connection conn, Channel channel) throws Exception;
	
	public void publicMsg() throws Exception{
		if(channel == null){
			init();
		}
		doSometing(conn, channel);
		close();
	}
	
}
